package com.atguigu.PracticalProject.app.dwd.log;

import com.atguigu.PracticalProject.app.BaseAppV1;
import com.atguigu.PracticalProject.common.Constant;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class DwdTrafficPageViewsDetail extends BaseAppV1 {
    public static void main(String[] args) {
        new DwdTrafficPageViewsDetail().init(
                3018,
                2,
                "DwdTrafficPageViewsDetail",
                Constant.TOPIC_DWD_TRAFFIC_PAGE
        );
    }
    @Override
    protected void handle(StreamExecutionEnvironment env, DataStreamSource<String> stream) {

        //

    }
}

/*
怎样才算一次会话？
一个会话会浏览一个或多个页面  每个页面都有停留时长。
(会话总数，时长总数)
 */